package com.wangbloc.domain.service;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author wangbloc
 * @version 1.0
 * @date 2023/2/9 23:17
 **/
public interface MqttMessageService {


    /**
     * 消息到达
     *
     * @param topic   主题
     * @param message 消息
     */
    void messageArrived(String topic, MqttMessage message);

}
